﻿// Copyright (c) 2009 CJSC NII STT (http://www.niistt.ru) and the 
// individuals listed on the AUTHORS entries.
// All rights reserved.
//
// Authors: 
//          Valentin Yakovenkov <yakovenkov@niistt.ru>
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions
// are met:
// 1.  Redistributions of source code must retain the above copyright
//     notice, this list of conditions and the following disclaimer.
// 2.  Redistributions in binary form must reproduce the above copyright
//     notice, this list of conditions and the following disclaimer in the
//     documentation and/or other materials provided with the distribution.
// 3.  Neither the name of CJSC NII STT ("NII STT") nor the names of
//     its contributors may be used to endorse or promote products derived
//     from this software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY NII STT AND ITS CONTRIBUTORS "AS IS" AND
// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
// ARE DISCLAIMED. IN NO EVENT SHALL NII STT OR ITS CONTRIBUTORS BE LIABLE FOR
// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
// DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
// OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
// HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
// STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
// IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
// POSSIBILITY OF SUCH DAMAGE.
//

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using KaorCore.RPU;
using KaorCore.Trace;
using KaorCore.Task;

namespace KaorCore.Task
{
	public class TraceTaskProvider : ITaskProvider
	{
		#region ================ Поля ================
		
		BaseTrace trace;
		Int64 measureIdx;
		//bool cycleMode;

		Guid taskCycleGuid;
		#endregion

		#region ================ Конструктор ================
		
		public TraceTaskProvider(BaseTrace pTrace)
		{
			trace = pTrace;
			measureIdx = 0;
//			cycleMode = true;
			taskCycleGuid = Guid.NewGuid();
		}

		#endregion

		#region ================ Проперти ================
		#endregion

		#region ITaskProvider Members

		public BaseTask NextTask()
		{
			TaskMeasurePower _task = null;

			if (measureIdx >= trace.TracePoints.Length - 1)
			{
				/// Больше нет заданий
				if (OnAllTasksComplete != null)
					OnAllTasksComplete(this);
				
				/// Если циклическое сканирование - сброс провайдера
				if (trace.IsCycle == true)
					Reset();
			}

			if (measureIdx == 0)
			{
				if (OnNewTaskCycle != null)
					OnNewTaskCycle(this, taskCycleGuid);
			}

			/// Здесь не должно быть else,
			/// т.к. обработчик окончания задания мог произвести сброс провайдера
			/// и может пойти сканирование заново
			if (measureIdx < trace.TracePoints.Length)
			{
				Int64 _freq;
				_freq = (Int64)trace.TracePoints[measureIdx].Freq;

				
				_task = new TaskMeasurePower(taskCycleGuid, _freq, measureIdx, trace.ScanParams);
				
				measureIdx++;
			}
		
			return _task;
		}

		public void TaskComplete(BaseTask pTask, BaseTaskResponse pResponse)
		{
			TaskMeasureResponse _resp = pResponse as TaskMeasureResponse;

			/// Проверка типа ответа
			if (_resp != null)
			{
				/// Прният правильный ответ, обрабатываем его в текущей трассе
				/// 

				TaskMeasurePower _req = pTask as TaskMeasurePower;

				if(_req == null)
					throw new ArgumentException("Request is not TaskMeasurePower");

				/// Обработка ответа трассой
				trace.ProcessMeasure(new TracePoint(_req.Frequency, _resp.Power));
			}
			else
			{
				throw new ArgumentException("Response is not TaskMeasureResponse");
			}
		}

		/// <summary>
		/// Сброс параметров провайдера
		/// </summary>
		public void Reset()
		{
			measureIdx = 0;
			taskCycleGuid = Guid.NewGuid();
		}

		public event AllTasksComplete OnAllTasksComplete;

		#endregion

		#region ITaskProvider Members
		/*
		public bool CycleMode
		{
			get
			{
				return cycleMode;
			}
			set
			{
				cycleMode = value;
			}
		}
		*/
		#endregion

		#region ITaskProvider Members


		public event NewTaskCycleDelegate OnNewTaskCycle;

		#endregion
	}
}
